package com.alibaba.datax.elasticresource.watcher;

import org.apache.flink.runtime.leaderelection.LeaderElectionService;
import org.apache.flink.runtime.rpc.FatalErrorHandler;

import com.alibaba.datax.common.util.Configuration;
import com.leehom.arch.rbt.watcher.DataxWatcher;

/**
 * @类名: DefaultDataxWatcherFactory
 * @说明: datax观测者工厂
 *
 * @author   leehom
 * @Date	 2024年8月26日 下午11:08:04
 * 修改记录：
 *
 * @see 	 
 */
public enum DefaultDataxWatcherFactory implements DataxWatcherFactory {
    INSTANCE;

	@Override
	public DataxWatcher createWatcher(Configuration configuration, 
			LeaderElectionService leaderElectionService,
			FatalErrorHandler fatalErrorHandler) throws Exception {
		
//		DataxWatcher watcher = new 
//				DataxWatcher(int reportInterval, 
//			    		StatisticsReportExporter<SummaryStatistics, Long> summaryReportRepository,
//						StatisticsReportRepository<SnapshotStatistics, SummaryStatistics, String> 
//							snapshotReportRepository)
		return null;
	}
	
	
}
